#!/bin/bash
# 定义变量：数据同步日期，表示同步哪一天日志数据
# 第1、执行shell脚本时，传递参数
# 第2、如果没有传递参数，同步前一天数据
if [ -n "$2" ] ; then
data_date=$2
else
data_date=`date -d "-1 days" +%F`
fi
# 加载数据语句
ODS_EVENT_APP_LOG_SQL="
LOAD DATA INPATH '/warehouse/app_logs/${data_date}' OVERWRITE INTO TABLE jtp_app_ods.ods_event_app_log
    PARTITION (dt = '${data_date}') ;
"
# 加载数据语句
ODS_MD_AREAS_SQL="
LOAD DATA INPATH '/warehouse/app_basic/t_md_areas/${data_date}'
    OVERWRITE INTO TABLE jtp_app_ods.ods_md_areas PARTITION (dt = '${data_date}');
"
## 执行脚本  [bwie@node101 ~]$ /opt/module/spark/bin/beeline --help
case $1 in
"all")
    /opt/module/spark/bin/beeline -u jdbc:hive2://node101:10001 -n bwie -e "${ODS_EVENT_APP_LOG_SQL}${ODS_MD_AREAS_SQL}"
    ;;
"ods_event_app_log")
    /opt/module/spark/bin/beeline -u jdbc:hive2://node101:10001 -n bwie -e "${ODS_EVENT_APP_LOG_SQL}"
  ;;
"ods_md_areas")
    /opt/module/spark/bin/beeline -u jdbc:hive2://node101:10001 -n bwie -e "${ODS_MD_AREAS_SQL}"
  ;;
esac